package com.ynet.middleground.riskmanage.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author liulx
 * @description 保理池相关通道
 * @date 2020-08-20 13:45
 */
public interface SinkBlch {

    /**
     * 中台接收入池信息
     */
    // String QQJY_TO_JKZTFK_BLCH= "qqjy_to_jkztfk_blch";
    /**
     * 中台接收入池信息
     */
    String QQJY_TO_JKZTFK_BLCH_IN = "qqjy_to_jkztfk_blch_in";
    /**
     * 中台接收入池信息
     */
    String QQJY_TO_JKZTFK_BLCH_OUT = "qqjy_to_jkztfk_blch_out";

    /**
     * 中台接收全球捷运推送的出入池信息
     *
     * @return
     */
    @Input(SinkBlch.QQJY_TO_JKZTFK_BLCH_IN)
    SubscribableChannel receiveIn();

    /**
     * 中台接收全球捷运推送的出入池信息
     *
     * @return
     */
    @Input(SinkBlch.QQJY_TO_JKZTFK_BLCH_OUT)
    SubscribableChannel receiveOut();

}
